package com.nightsoul.disruptor.test;

import com.lmax.disruptor.EventHandler;

public class MsgEventHandler implements EventHandler<MsgEvent> {

	@Override
	public void onEvent(MsgEvent event, long sequence, boolean endOfBatch) throws Exception {
		System.out.println(Thread.currentThread().getName() + "," + event);
	}

}
